package com.gsm.partition;

import org.apache.flink.api.common.functions.Partitioner;

/**
 * TODO
 *
 * @author gsm
 * @version 1.0
 */
public class MyPartitioner implements Partitioner<String> {

    @Override
    public int partition(String key, int numPartitions) {
//        return 0;

        return Integer.parseInt(key) % numPartitions;

//        return Integer.parseInt(key) % 2;
//        return Integer.parseInt(1) % 2; -> 1
//        return Integer.parseInt(2) % 2; -> 0
//        return Integer.parseInt(3) % 2; -> 1
//        return Integer.parseInt(4) % 2; -> 0
//        return Integer.parseInt(5) % 2; -> 1
//        return Integer.parseInt(6) % 2; -> 0
    }
}
